package com.distributer.delayqueue.delayqueue;

import com.distributer.delayqueue.job.JobMsg;
import com.distributer.delayqueue.support.LifeCycle;


public interface Queue extends LifeCycle{

	public void putJobMsg(JobMsg jobMsg);
	
	public boolean deleteJob(String jobId);
	
	public void ack(String jobId);
	
	public JobMsg getJobByJobId(String jobId);
	
	public long getSize();
	
	public void clear();
	
	
}
